package com.cryann.mqttserver.mqttProcess;

import io.netty.channel.Channel;

/**
 * @author cRyann
 * @date 2018/12/14 0014 11:27
 * @description:
 */
public interface BasicProcess<T> {
    /**
     * Mqtt消息处理抽象类
     *
     * @param ctx netty 通道
     * @param t   泛型
     * @return void
     */
    void process(Channel ctx, T t);
}
